Skip to content

Doppio live processing requirements#790

Draft
stephen-riggs wants to merge 11 commits intomainfrom
doppio-live-processing
Draft

Doppio live processing requirements#790
stephen-riggs wants to merge 11 commits intomainfrom
doppio-live-processing

Conversation

@stephen-riggs
Copy link
Copy Markdown
Contributor

No description provided.

"""
project_dir = Path(visit_name)
pipeline_file = project_dir / "default_pipeline.star"
if not pipeline_file.is_file():
Falls back to the positional default job002 and logs a warning so
drift from the live pipeline is visible in the logs instead of silent.
"""
project_dir = Path(visit_name).resolve()
project_dir = Path(visit_name).resolve()
pipeline_file = project_dir / "default_pipeline.star"
try:
mtime_ns = pipeline_file.stat().st_mtime_ns
Comment on lines +458 to +459
f"Pre-processing was requested for {session_id} "
"but no Zocalo transport object was found"
logger.error(
"ProjectGraph read failed while looking up alias %r in %s",
alias,
pipeline_file,
except FileNotFoundError:
logger.warning(
"default_pipeline.star missing at %s — falling back to %s for alias %r",
pipeline_file,
logger.warning(
"Alias %r not found in %s — falling back to %s",
alias,
pipeline_file,
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants